package cn.oldsix.spark.core.phone

import org.apache.hadoop.mapred.lib.MultipleTextOutputFormat

/**
  * @ Author : Wu.D.J
  * @ Create : 2017.08.01
  */
class RDDMultipleTextOutputFormat extends MultipleTextOutputFormat[Any, Any]{
    override def generateFileNameForKeyValue(key: Any, value: Any, name: String): String = {
        key.asInstanceOf[String].split("\t")(1) + ".txt"
    }
}
